package com.ly.kafka.config;

import lombok.Data;

import java.util.function.Consumer;

/**
 *
 * kafka顺序消费线程池配置参数
 *
 * @author baiyan
 * @date 2022-01-19
 */
public class KafkaSortConsumerConfig<E> {

    /**
     * 业务名称
     */
    String bizName;

    /**
     * 并发级别，多少的队列与线程处理任务
     */
    Integer concurrentSize;

    /**
     * 业务处理服务 可以指定多个 订单 支付 等等
     * Consumer java的一个功能接口 用来作为lambda表达式或方法引用的任务目标(传递一个参数执行指定的方法)
     */
    Consumer<E> bizService;

    public String getBizName() {
        return bizName;
    }

    public void setBizName(String bizName) {
        this.bizName = bizName;
    }

    public Integer getConcurrentSize() {
        return concurrentSize;
    }

    public void setConcurrentSize(Integer concurrentSize) {
        this.concurrentSize = concurrentSize;
    }

    public Consumer<E> getBizService() {
        return bizService;
    }

    public void setBizService(Consumer<E> bizService) {
        this.bizService = bizService;
    }
}
